package cn.remexs.flink.udf.geo;

import cn.remexs.flink.udf.GeoUtils;
import org.apache.flink.table.annotation.DataTypeHint;
import org.apache.flink.table.functions.ScalarFunction;

import java.math.BigDecimal;

/**
 * 坐标转换
 */
public class BuildWkt extends ScalarFunction {
    public BuildWkt() {
    }

    public String eval(@DataTypeHint("DECIMAL(32,16)") BigDecimal lon, @DataTypeHint("DECIMAL(32,16)") BigDecimal lat) {
        return GeoUtils.buildWkt(lon.doubleValue(), lat.doubleValue());
    }
}
